#include "threadPool.h"

int threadPoolInit(threadPool_t *pthreadPool,int workerNum)
{
    tidArrInit(&pthreadPool->tidArr,workerNum);// 初始化子线程信息
    taskQueueInit(&pthreadPool->taskQueue);// 初始化任务队列
    pthread_mutex_init(&pthreadPool->mutex,NULL);// 初始化锁
    pthread_cond_init(&pthreadPool->cond,NULL);// 初始化条件变量
    return 0;
}
//
//// 创建子线程
//int makeWorker(threadPool_t *pthreadPool)
//{
//    for(int i=0;i<pthreadPool->tidArr.workerNum;i++)
//    {
//        pthread_create(&pthreadPool->tidArr.arr[i],NULL,threadFunc,pthreadPool);
//    }
//    return 0;
//}
